package com.kafka.utils;

/**
 * @author xin.ding
 * @date 2019/12/7 15:15
 */
public interface ConsumerInterface {

    /**
     * 普通的消费者
     *
     * @param topic 主题
     */
    public void consumer(String topic);

    /**
     * 批量消费
     *
     * @param topic 主题
     * @param num   批量消费的数量
     */
    public void consumerBatch(String topic, int num);

    /**
     * 指定从哪里开始消费数据
     *
     * @param topic 主题
     * @param line  具体的位置
     */
    public void consumerFromDetailPosition(String topic, long line);
}


